package com.bbx.flink.demo;

import org.apache.flink.streaming.api.functions.source.ParallelSourceFunction;
import org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction;

///**
// * 方法一：并行的源
// */
//public class Parallelsources implements ParallelSourceFunction {
//    @Override
//    public void run(SourceContext ctx) throws Exception {
//
//    }
//
//    @Override
//    public void cancel() {
//
//    }
//}


/**
 * 方法二：并行的源
 */
public class Parallelsources extends RichParallelSourceFunction {

    private static final long serialVersionUID = -1094600833146001566L;

    @Override
    public void run(SourceContext ctx) throws Exception {

    }

    @Override
    public void cancel() {

    }
}